package com.horay.springclouddemo.stream.multiple.provider.message;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Component;

/**
 * 消息处理器
 *
 * @author heyingcheng
 * @date 2020/3/29 15:35
 */
@Component
public interface MessageSource {

    String LOG_OUTPUT = "log_output";

    @Output(LOG_OUTPUT)
    MessageChannel logOutput();

}
